package com.consente.demo.netty.service;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.net.InetSocketAddress;

/**
 * netty启动通用接口
 */
@Component
public class NettyServerStarterTemplate {
    Logger log = LoggerFactory.getLogger(NettyServerStarterTemplate.class);
    @Value(value = "${netty.netdev.port:10090}")
    private String port;
    @Value(value = "${netty.netdev.host:0.0.0.0}")
    private String host;
    @Value(value = "${netty.netdev.workGroupThreadCount:5}")
    private String workGroupThreadCount;

    public void start() {
//        InetSocketAddress socketAddress = new InetSocketAddress(host,Integer.parseInt(port));
        InetSocketAddress socketAddress = new InetSocketAddress(host,Integer.parseInt(port));
        //new 一个主线程组
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        //new 一个工作线程组
        EventLoopGroup workGroup = new NioEventLoopGroup(getWorkGroupThreadCount());
        ServerBootstrap bootstrap = new ServerBootstrap()
                .group(bossGroup, workGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new NettyServerInitializerTemplate())
                .localAddress(socketAddress)
                //设置队列大小
                .option(ChannelOption.SO_BACKLOG, 1024)
                // 两小时内没有数据的通信时,TCP会自动发送一个活动探测数据报文
                .childOption(ChannelOption.SO_KEEPALIVE, true)
                ;
        //绑定端口,开始接收进来的连接
        try {
            ChannelFuture future = bootstrap.bind(socketAddress).sync();
            log.info("服务器启动开始监听端口: {}", socketAddress.getPort());
            future.channel().closeFuture().sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            //关闭主线程组
            bossGroup.shutdownGracefully();
            //关闭工作线程组
            workGroup.shutdownGracefully();
        }
    }

//    /**
//     * 返回继承类，用于写日志
//     * @return
//     */
//    protected abstract Class<?> getClassse();
//
//    /**
//     * 返回netty连接器枚举
//     * @return
//     */
//    public abstract DataTypeEnum getDataTypeEnum();
//
//    /**
//     * 设置socket链接地址
//     * @return
//     */
//    protected abstract InetSocketAddress getInetSocketAddress();

    /**
     * 获取工作线程组线程数
     * @return
     */
    protected Integer getWorkGroupThreadCount(){
        return Integer.parseInt(workGroupThreadCount);
    }
}
